//package com.xyz.graph.task;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.beans.factory.annotation.Qualifier;
//import org.springframework.jdbc.core.JdbcTemplate;
//import org.springframework.stereotype.Component;
//
//import java.util.List;
//import java.util.Map;
//
//@Slf4j
//@Component
//public class DataTask {
//    @Autowired
//    @Qualifier("impalaJdbcTemplate")
//    private JdbcTemplate impalaJdbcTemplate;
//
//    public List<Map<String,Object>> SelectImapalaTask(String sql){
//        List<Map<String,Object>> mapList = null;
//        try{
//            impalaJdbcTemplate.setQueryTimeout(6000);
//            mapList=impalaJdbcTemplate.queryForList(sql);
//            log.info("查询成功，sql = {}",sql);
//        }catch (Exception e){
//            //todo 查询失败的语句入库
//            log.info("查询失败，sql = {}，error:{}",sql,e);
//        }
//
//        return mapList;
//    }
//
//    public int updateImapalaTask(String sql){
//        int num = 0;
//        try{
//            impalaJdbcTemplate.setQueryTimeout(6000);
//            num=impalaJdbcTemplate.update(sql);
//            log.info("更新成功，sql = {}",sql);
//        }catch (Exception e){
//            //todo 查询失败的语句入库
//            log.info("更新失败，sql = {}，error:{}",sql,e);
//        }
//
//        return num;
//    }
//}
